package edu.corn.job.core.engine.mutex;

import edu.corn.job.core.context.JobRunningContext;
import edu.corn.job.core.processor.MutexProcessor;

import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;

/**
 *
 */
public class LocalMutexPool implements MutexPool {

    protected ConcurrentHashMap<Enum<?>, Set<Short>> mutexes = new ConcurrentHashMap<>();

    @Override
    public Boolean lock(MutexProcessor processor) {
        return true;
    }

    @Override
    public void unlock(MutexProcessor processor) {

    }

    @Override
    public Boolean lock(MutexProcessor processor, long timeout) {
        return null;
    }

    @Override
    public Boolean lock(JobRunningContext context) {
        return null;
    }

    @Override
    public Boolean lock(String key) {
        return null;
    }

    @Override
    public Boolean lock(String key, long timeout) {
        return null;
    }
}
